8f4fbd0da68a054a6d713b8ec1cc0f9e07e02627,spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/KafkaBinderTests.java,KafkaBinderTests,testAutoCreateTopicsDisabledFailsIfTopicMissing,#,910

Before Change


		ExtendedConsumerProperties<KafkaConsumerProperties> consumerProperties = createConsumerProperties();
		String testTopicName = "nonexisting" + System.currentTimeMillis();
		try {
			binder.bindConsumer(testTopicName, "test", output, consumerProperties);
			fail();
		}
		catch (Exception e) {

After Change


		String testPayload = "foo1-" + UUID.randomUUID().toString();
		output.send(new GenericMessage<>(testPayload.getBytes()));

		Binding<MessageChannel> consumerBinding = binder.bindConsumer(testTopicName, "test", input, consumerProperties);
		Message<byte[]> receivedMessage2 = (Message<byte[]>) receive(input);
		assertThat(receivedMessage2).isNotNull();
		assertThat(new String(receivedMessage2.getPayload())).isEqualTo(testPayload);